from celery import Celery
import os
import django

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'luffyapi.settings.dev')
django.setup()

os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')
# 1. 创建celery对象实例 (可以创建多个应用)
app = Celery('luffy')
# app2 = Celery('luffy_shop')
# 2. 加载配置 (给应用对象指定任务队列以及结果队列)
app.config_from_object('mycelery.config')

# 3. 自动发现任务
app.autodiscover_tasks(['mycelery.sms','mycelery.email' ])